package writer.es;


import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;


/*
    传递给下游的数据缓冲队列
 */
public class TaskQueue {

    public static BlockingQueue<TraceDataBean> queue = new LinkedBlockingQueue<TraceDataBean>();


    public static BlockingQueue<TraceDataBean> getQueue() {
        return queue;
    }

}
